package org.niit.controller

import org.apache.spark.streaming.dstream.DStream
import org.niit.bean.AdClickData
import org.niit.service.{BlackListService, TimeCountService}

/**
 * Date:2025/5/30
 * Author：Ys
 * Description:
 */
class BlackListController {
    val blackListService = new BlackListService()
    val timeCountService = new TimeCountService()
  def dispath(data:DStream[AdClickData]): Unit = {
    // 调用相应的Service的模块
    blackListService.dataAnalysis(data)

    timeCountService.dataAnalysis(data)
  }

}
